package top.doe.spark.netty

import top.doe.spark.rpc.{RpcEndpointAddress, RpcEndpointRef}
import top.doe.spark.util.RpcAddress

class NettyRpcEndpointRef(
  endpointAddress: RpcEndpointAddress,
  var nettyEnv: NettyRpcEnv
) extends RpcEndpointRef{

  override def name: String = endpointAddress.name

  override def address: RpcAddress = endpointAddress.rpcAddress

  //TODO send 发送异步消息
  override def send(message: Any): Unit = {

  }

  //TODO ask 发送同步消息
}
